/*
 * Copyright © 2018 www.noark.xyz All Rights Reserved.
 *
 * 感谢您选择Noark框架，希望我们的努力能为您提供一个简单、易用、稳定的服务器端框架 ！
 * 除非符合Noark许可协议，否则不得使用该文件，您可以下载许可协议文件：
 *
 *        http://www.noark.xyz/LICENSE
 *
 * 1.未经许可，任何公司及个人不得以任何方式或理由对本框架进行修改、使用和传播;
 * 2.禁止在本项目或任何子项目的基础上发展任何派生版本、修改版本或第三方版本;
 * 3.无论你对源代码做出任何修改和改进，版权都归Noark研发团队所有，我们保留所有权利;
 * 4.凡侵犯Noark版权等知识产权的，必依法追究其法律责任，特此郑重法律声明！
 */
package xyz.noark.network.codec.json;

import com.alibaba.fastjson2.JSON;
import io.netty.buffer.ByteBuf;
import io.netty.handler.codec.ByteToMessageDecoder;
import xyz.noark.core.lang.ByteArray;
import xyz.noark.core.lang.ByteArrayOutputStream;
import xyz.noark.core.lang.ImmutableByteArray;
import xyz.noark.core.network.NetworkPacket;
import xyz.noark.core.network.NetworkProtocol;
import xyz.noark.network.codec.AbstractPacketCodec;
import xyz.noark.network.codec.ByteBufWrapper;
import xyz.noark.network.codec.DefaultNetworkPacket;

/**
 * Json封包解码器.
 *
 * @author 小流氓[176543888@qq.com]
 * @since 3.0
 */
public class SimpleJsonCodec extends AbstractPacketCodec {

    @Override
    public <T> T decodeProtocol(ByteArray bytes, Class<T> klass) {
        return JSON.parseObject(bytes.array(), klass);
    }

    @Override
    public ByteArray encodePacket(NetworkProtocol networkProtocol) {
        final byte[] bytes = JSON.toJSONBytes(networkProtocol.getProtocol());

        ImmutableByteArray byteArray = new ImmutableByteArray(bytes.length + 4);
        try (ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(byteArray)) {
            // 写入Opcode
            byteArrayOutputStream.writeInt((Integer) networkProtocol.getOpcode());
            // 写入协议内容
            byteArrayOutputStream.writeBytes(bytes);
        }
        return byteArray;
    }

    @Override
    public SimpleJsonLengthEncoder lengthEncoder() {
        return new SimpleJsonLengthEncoder();
    }

    @Override
    public ByteToMessageDecoder lengthDecoder() {
        return new SimpleJsonLengthDecoder(this);
    }

    @Override
    public NetworkPacket decodePacket(ByteBuf byteBuf) {
        DefaultNetworkPacket packet = new DefaultNetworkPacket();
        packet.setLength(byteBuf.readableBytes());
        packet.setOpcode(byteBuf.readInt());
        packet.setBytes(new ByteBufWrapper(byteBuf));
        return packet;
    }
}